package com.chennan.rebbitmq.nantest.simple;

import com.chennan.rebbitmq.uitl.MqConnection;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/**
 * @author chennan
 * @create 2022-04
 */
public class ProducerSimple {

    public static void main(String[] args) throws Exception{
        Connection connection = MqConnection.getConnection();
        Channel channel = connection.createChannel();
        String msg = "11111111111111111";
        MqConnection.basicPublish(channel,ConsumerSimple.ConsumerSimpleExchange,ConsumerSimple.SimpleroutingKey,msg);
    }
}
